package com.hugang.newfeature.streamapi;

import com.hugang.newfeature.methodrefernce.Employee;
import com.hugang.newfeature.methodrefernce.EmployeeData;
import org.junit.Test;

import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;

/**
 * StreamAPI终止操作
 *
 * @author hg
 * @date 2020/6/26 22:51
 */
public class StreamAPITest2 {

    /**
     * 终止操作
     *
     */
    @Test
    public void test(){
        List<Employee> employees = EmployeeData.getEmployees();
        //1）匹配与查找
        //allMatch(Predicate p) —— 检查是否匹配所有元素。
        //练习：是否所有的员工的年龄都大于18
        boolean b = employees.stream().allMatch(e -> e.getAge() > 18);
        System.out.println(b);
        //anyMatch(Predicate p) —— 检查是否至少匹配一个元素
        //练习：是否存在工资大于10000的员工
        boolean b1 = employees.stream().anyMatch(e -> e.getSalary() > 10000);
        System.out.println(b1);
        //noneMatch(Predicate p) —— 检查是否没有匹配的元素
        //练习：是否不存在姓雷的员工
        boolean b2 = employees.stream().noneMatch(e -> e.getName().startsWith("雷1"));
        System.out.println(b2);
        //findFirst —— 返回第一个元素
        Optional<Employee> first = employees.stream().findFirst();
        System.out.println(first);
        //findAny —— 返回当前流中的任意元素
        Optional<Employee> any = employees.parallelStream().findAny();
        System.out.println(any);
        //count —— 返回流中元素的总个数
        long count = employees.stream().filter(employee -> employee.getSalary() > 5000).count();
        System.out.println(count);
        //max(Comparator c) —— 返回流中的最大值
        //练习：返回最高的工资
        Optional<Double> max = employees.stream().map(Employee::getSalary).max(Double::compare);
        System.out.println(max);
        //min(Comparator c) —— 返回流中的最小值
        //练习：返回最低的年龄
        Optional<Integer> min = employees.stream().map(Employee::getAge).min(Integer::compare);
        System.out.println(min);
        //forEach(Consume c) —— 内部迭代
        employees.stream().forEach(System.out::println);
        //使用集合的遍历操作
        employees.forEach(System.out::println);


        //2）归约
        //reduce(T identity, BinaryOperator) —— 可以将流中的元素反复结合起来，得到一个值。返回T
        //练习：计算1-10的自然数的和
        List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
        Integer reduce = list.stream().reduce(0, Integer::sum);
        System.out.println(reduce);
        //reduce(BinaryOperator) —— 可以将流中元素反复结合起来，得到一个值，返回Optional<T>
        //练习：计算公司所有员工工资的总和
        Stream<Double> salaryStream = employees.stream().map(Employee::getSalary);
//        Optional<Double> reduce1 = salaryStream.reduce(Double::sum);
        Optional<Double> reduce1 = salaryStream.reduce((d1, d2) -> d1 + d2);
        System.out.println(reduce1);


        //3）收集
        //collect(Collector c) —— 将流转换为其他形式。接收一个Collector接口的实现，用于给Stream中元素做汇总的方法
        //练习：查找工资大于6000的员工，结果返回为一个List或Set
        List<Employee> collect = employees.stream().filter(e -> e.getSalary() > 6000).collect(Collectors.toList());
        collect.forEach(System.out::println);
        System.out.println();
        Set<Employee> collect1 = employees.stream().filter(e -> e.getAge() < 40).collect(Collectors.toSet());
        collect1.forEach(System.out::println);
    }
}
